package com.example.elasticsearchdemo.module.location.dao;

import com.example.elasticsearchdemo.module.location.entity.Location;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.annotations.Query;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.data.querydsl.binding.QuerydslPredicate;
import org.springframework.data.repository.PagingAndSortingRepository;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Repository;
import org.springframework.util.concurrent.ListenableFuture;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Future;
import java.util.stream.Stream;

/**
 * @author wangjianhua
 * @Description
 * @date 2021/7/8/008 10:26
 */
@Repository
public interface LocationRepository extends ElasticsearchRepository<Location,String> {

    /**
     * 通过es原生语法查询
     * @return 流
     */
//    @Query("quer": {\n" +
//            "    \"match_all\": {}\n" +
//            "  }\"")
//    Stream<Location> findByCustomQuery();

    /**
     * 自定义条件并通过该语法查询
     * @param pageble 查询条件
     * @return
     */
    @Query("select l from test ")
    Stream<Location> findByCustomQueryAndPage(Pageable pageble);
//
//    /**
//     * 异步查询
//     * @param pageble 查询条件
//     * @return
//     */
//    @Async
//    @Query("select l from Location l")
//    Future<Location> findByIdAsync(Pageable pageble);
//
//    /**
//     * 异步查询表现形式
//     * @param pageble 查询条件
//     * @return
//     */
//    @Async
//    @Query("select l from Location l")
//    CompletableFuture<Location> findByIdAsync1(Pageable pageble);
//
//    /**
//     * 异步查询表现形式
//     * @param pageble 查询条件
//     * @return
//     */
//    @Async
//    @Query("select l from Location l")
//    ListenableFuture<Location> findByIdAsync2(Pageable pageble);
}
